package com.pan.common.concurrency.example.threadPool;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author by panstark
 * @description
 * @notice
 * @date 2021/4/1
 */
public class PoolQueue {

    ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue(16);

    public void add () throws InterruptedException {
        arrayBlockingQueue.offer("111");
        Object take = arrayBlockingQueue.take();

    }
}
